package com.trip.order.producer;

import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;

import java.util.List;
import java.util.Map;

public abstract class AbstractRocketMQService implements IRocketMQService{
    public AbstractRocketMQService() {
        super();
    }

    @Override
    public SendResult sendMessage(String destination, Object msg) {
        return null;
    }

    @Override
    public SendResult sendMessage(String topicName, String tags, Object msg) {
        return null;
    }

    @Override
    public SendResult sendMessage(String topicName, String tags, String key, Object msg) {
        return null;
    }

    @Override
    public SendResult sendMessageBySql(String topicName, Map<String, Object> map, Object msg) {
        return null;
    }

    @Override
    public SendResult sendMessageBySql(String topicName, Map<String, Object> map, String key, Object msg) {
        return null;
    }

    @Override
    public void sendAsyncMessage(String destination, Object msg, SendCallback sendCallback) {

    }

    @Override
    public void sendOneway(String destination, Object msg) {

    }

    @Override
    public void sendBatchMessage(String destination, List<?> list) {

    }

    @Override
    public void sendBatchMessage(String topicName, String tags, Long timeout, List<?> list) {

    }

    @Override
    public SendResult sendDelayLevel(String destination, Object msg, int delayTimeLevel) {
        return null;
    }

    @Override
    public SendResult sendDelayLevel(String destination, Object msg, int timeout, int delayTimeLevel) {
        return null;
    }

    @Override
    public SendResult sendInOrder(String destination, Object msg, String hashKey) {
        return null;
    }

    @Override
    public SendResult sendMessageInTransaction(String destination, Object msg, Object arg) {
        return null;
    }

    @Override
    public boolean sendMessage(String topicName, String tags, String key, String msg) {
        return false;
    }
}
